package com.activemq.service;

import javax.jms.Destination;

/**
 * 消息生产者
 */
public interface ProducerService {
    //========================== 点对点模式 ==============================
    /**
     * 指定消息队列，发送消息
     * @param destination
     * @param message
     */
    void sendMessage(Destination destination,String message);

    /**
     * 使用默认消息队列，发送消息
     * @param message
     */
    void sendMessage(String message);

    //========================== 发布订阅模式 ==============================

    /**
     * 发布订阅：消息发布者
     * @param message
     */
    void publish(String message);
}
